const express=require("express")
const router=express.Router()

const mysql = require("mysql")
const conn = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'root',
    database: "yunheshop",
    port: '3306'
})

//列表渲染
router.get("/list",(req,res)=>{
    let {page}=req.query;
    let pagesize=10;
    let start=(page-1)*pagesize;
    let sql="select * from midata  order by id asc limit ?,?";
    conn.query(sql,[start,pagesize],(err,result)=>{
        if(err){
            console.log("服务器出错");
            return ;
        }
        let data;
        if(result.length){
            data={
                code:0,
                list:result
            }
        }else{
            data={
                code:1,
                msg:"没有数据了"
            }
        }
        res.send(data);
    })
}) 
//点击加入购物车
router.get("/addcart",(req,res)=>{
    let {proid,userid}=req.query;
    //查询购物车中该用户购买此商品的数量
    let sql="select * from cart where proid=? and userid=? order by cartid asc";
    conn.query(sql,[proid,userid],(err,result)=>{
        if(err){
            console.log("服务器出错");
            return ;
        }
        let num=0;
        if(result.length){//购物车中存在用户购买此商品的信息,获取num,并修改数据库信息
            num=++result[0].num;
            let cartid=result[0].cartId;
            let sql="update cart set num=? where cartid=?";
            conn.query(sql,[num,cartid],(err,result)=>{
                if(err){
                    console.log("服务器出错");
                    return ;
                }
                let data;
                if(result.affectedRows){
                    data={
                        code:0,
                        msg:"购物车数量修改成功"
                    }
                }else{
                    data={
                        code:1,
                        msg:"购物车数量修改失败"
                    }
                }
                res.send(data);
            })
            return;
        }
        //把数据插入购物车数据库中
        num++;
        let sql="insert into cart (proid,userid,num) values (?,?,?)";
        conn.query(sql,[proid,userid,num],(err,result)=>{
            if(err){
                console.log("服务器出错");
                return ;
            }
            let data;
            if(result.affectedRows){
                data={
                    code:2,
                    msg:"加入购物车成功"
                }
            }else{
                data={
                    code:3,
                    msg:"加入购物车失败"
                }
            }
            res.send(data);
        });
    })
})


module.exports=router;